package cn.com.greatwall.kafka.domain.vo;

import java.util.List;

import org.apache.kafka.common.ConsumerGroupState;

import cn.com.greatwall.kafka.util.enums.KafkaCenterGroupState;
import lombok.Getter;
import lombok.Setter;

/**
 * @Author herw
 * @Time 2021-04-07 10:21:16
 * @Version 1.0
 * @Description: TODO(用一句话描述该文件做什么)
 */
@Getter
@Setter
public class GroupTopicConsumerState {
    private String group;
    private String topic;
    private String consumerMethod;
    private List<PartitionAssignmentState> partitionAssignmentStates;
    private KafkaCenterGroupState kafkaCenterGroupState;
    private ConsumerGroupState consumerGroupState;
    private boolean isSimpleConsumerGroup = false ;
    private boolean hasMembers;
    
    public GroupTopicConsumerState(String group,String topic,String consumerMethod){
        this.group = group;
        this.topic = topic;
        this.consumerMethod = consumerMethod;
    }
}
